package com.kafka.test.producer;

import org.apache.kafka.clients.producer.Partitioner;
import org.apache.kafka.common.Cluster;

import java.util.Map;

/**
 * Created with IntelliJ IDEA.
 *
 * @Author: DongGuoZhen
 * @Date: 2025/03/29/11:12
 * @Description:
 */
// 自定义分区器  实现 Partitioner接口 重写方法
public class MyKafkaPartitioner implements Partitioner {
    @Override
//    该方法为计算具体分区的方法 这里我们直接返回0分区
    public int partition(String s, Object o, byte[] bytes, Object o1, byte[] bytes1, Cluster cluster) {
        return 0;
    }
    @Override
    public void close() {

    }
    @Override
    public void configure(Map<String, ?> map) {
    }
}
